301d60411fb2765d1b53779b320abdb9446b8757,debezium-connector-mysql/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java,MySqlValueConverters,schemaBuilder,#Column#,82
Before Change
}
if (matches(typeName, "SET")) {
List<String> options = extractEnumAndSetOptions(column);
StringBuilder commaSeparatedOptions = new StringBuilder();
boolean first = true;
for (String value:options) {
if (first) {
first = false;
} else {
commaSeparatedOptions.append(MySqlDdlParser.ENUM_AND_SET_DELIMINATOR);
}
commaSeparatedOptions.append(value);
}
return io.debezium.data.EnumSet.builder(commaSeparatedOptions.toString());
}
// Otherwise, let the base class handle it ...
return super.schemaBuilder(column);
After Change
}
if (matches(typeName, "SET")) {
List<String> options = extractEnumAndSetOptions(column);
String commaSeperatedOptions = Strings.join(MySqlDdlParser.ENUM_AND_SET_DELIMINATOR,options);
return io.debezium.data.EnumSet.builder(commaSeperatedOptions);
}
// Otherwise, let the base class handle it ...